package com.atguigu.app.dws;

import com.atguigu.util.MyKafkaUtil_lj;
import org.apache.flink.streaming.api.datastream.DataStreamSource;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

/**
 * @Author 晶晶
 * @Date 2023 03 28 19 17
 **/
public class Dws_StudyPaperScoreStatistics {
    public static void main(String[] args) {
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
        env.setParallelism(1);

        String topic = "";
        String groupId = "";
        DataStreamSource<String> kafkaDs = env.addSource(MyKafkaUtil_lj.getFinkKafkaConsumer(topic, groupId));
    }
}
